
// 引入express模块
const express = require('express')
// 引入连接池对象
const pool = require('../pool')
//创建路由器对象
const r = express.Router()


// 用户注册模块
// URL:http://127.0.0.1:3000/v1/users/reg
r.post('/reg', (req, res, next) => {
    // 获取用户传递的参数
    // console.log(req.body);
    var sql = 'insert into library_user set ?'
    pool.query(sql, [req.body], (err, result) => {
        if (err) {
            next(err)
            return
        }
        res.send({ code: 200, msg: '注册成功' })
    })
})
// 用户注册模块
// 判断用户名是否存在
// URL:http://127.0.0.1:3000/v1/users/check_name?uname=lili
r.get('/check_name', (req, res, next) => {
    // 获取用户传递的参数
    let n = req.query.uname
    // console.log(n);
    pool.query('select uid from library_user where uname=?', [n], (err, result) => {
        if (err) {
            next(err)
            return
        }
        // console.log(result);
        if (result.length > 0) {
            res.send('该用户名已被注册')
        } else {
            res.send('ok')
        }
    })
})

// 用户注册模块
//  判断邮箱是否存在以及是否符合规范
// URL:http://127.0.0.1:3000/v1/users/check_email?email=lili@qq.com

r.get('/check_email', (req, res, next) => {
    // 获取用户传递的邮箱
    let n = req.query.email
    // console.log(n);
   
    var sql = 'select uid from library_user where email=?'
    pool.query(sql, [n], (err, result) => {
        if (err) {
            next(err)
            return
        }
        // 判断数据库是否已经存在该邮箱
        if (result.length > 0) {
            res.send('该邮箱已被注册')
        } else {
            res.send('ok')
        }
    })
})

// 用户注册模块
//  判断手机号是否存在以及是否符合规范
// URL:http://127.0.0.1:3000/v1/users/check_phone?13253359304
r.get('/check_phone', (req, res, next) => {
    // 获取用户传递的手机号
    let n = req.query.phone
    console.log(n);
    // res.send('ok')
  
    // console.log(n);
    pool.query('select uid from library_user where phone=?', [n], (err, result) => {
        if (err) {
            next(err)
            return
        }
         // 判断数据库是否已经存在该手机号
         if (result.length > 0) {
            res.send('该手机号已被注册')
        } else {
            res.send('ok')
        }
    })
})







// 用户登录路由
// URL:http://127.0.0.1:3000/v1/users/login?uname=lili&upwd=123456
r.get('/login', (req, res, next) => {
    // 获取用户传递的参数
     console.log(req.query);

    var sql = 'select * from library_user where uname=? and upwd=?'
    // 执行sql语句
    pool.query(sql, [req.query.uname, req.query.upwd], (err, result) => {
        if (err) {
            next(err)
            return
        }
        console.log(result);
        // 成功的结果是一个数组，判断数组是否为空，如果是空数组就登录失败
        if (result.length == 0) {
            res.send({ code: 402, msg: '登录失败' })
        } else {
            res.send({ code: 200, msg: '登录成功' })
        }
    })
})


// 修改用户信息模块
// URL:http://127.0.0.1:3000/v1/users/
r.put('/', (req, res, next) => {
    // 获取用户传递的数据
    var obj = req.body
    // 执行sql命令
    var sql = 'update library_user set ? where uid=1'
    pool.query(sql, [obj, obj.uid], (err, result) => {
        if (err) {
            next(err)
            return
        }
        console.log(result);
        if (result.affected === 0) {
            res.send({ code: 501, msg: '修改信息失败' })
        } else {
            res.send({ code: 200, msg: '修改信息成功' })
        }
    })
})





// 用户列表模块











// 将用户路由器暴露出去
module.exports = r
